package com.hhly.rabbitmq.topic;

import java.io.IOException;

import com.hhly.rabbitmq.RabbitMQUtil;
import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Consumer;
import com.rabbitmq.client.DefaultConsumer;
import com.rabbitmq.client.Envelope;

public class RabbitMqLogs {
     public static void main(String[] args) throws IOException {
    	 Channel channel = RabbitMQUtil.getChannel();
    	 channel.queueDeclare("rabbitmq.log.info.test", false, true, true, null);
      	 channel.queueBind("rabbitmq.log.info.test","amq.rabbitmq.log", "info");
      	 Consumer consumer = new DefaultConsumer(channel) {
    			@Override
    			public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties,
    					byte[] body) throws IOException {
    				String message = new String(body, "UTF-8");
    				System.out.println(" [x] Received '" + message + "'");
    			}
    		};
    		channel.basicConsume("rabbitmq.log.info.test", true, consumer);      
	}
}
